package top.ewind.interceptor.mqtt;

import java.nio.ByteBuffer;

/**
 * @author wangchao
 *
 */
public interface IMsgStrategy {

	public void onConnect(String id);
	public void onDisconnect(String id);
	public void onPublish(String pid,String id,ByteBuffer buff);
	
}
